package com.apex.flink.batch;

import com.apex.flink.FlinkBaseSink;
import com.apex.flink.FlinkEnvironment;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.operators.DataSink;

public interface FlinkBatchSink<IN, OUT> extends FlinkBaseSink {
    DataSink<OUT> outputBatch(FlinkEnvironment env, DataSet<IN> inDataSet);
}
